package com.sqin.taskflow.config;

import com.sqin.taskflow.listen.ITaskListen;
import lombok.Data;
import lombok.Getter;
import lombok.Setter;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

@Getter
@Setter
@Data
public class TaskFlowConfig {

    public static ITaskListen listen;

    public static int corePoolSize = 8;
    public static int maximumPoolSize = 16;
    public static  long keepAliveTime = 3;
    public static TimeUnit unit = TimeUnit.SECONDS;
    public static  BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(1000);

}
